package com.taoban.shopdata.utils;

import com.taoban.shopdata.core.AbstractShopDataConsumer;
import com.taoban.shopdata.core.impl.AmazonShopDataConsumer;
import com.taoban.shopdata.core.impl.YHDShopDataConsumer;
import com.taoban.shopdata.entity.PriceUpdatedCommitResult;

public class FactoryUtils {
public static <I,R> AbstractShopDataConsumer<I,R> getShopDataConsumer(PriceUpdatedCommitResult priceUpdatedCommitResult){
	if(priceUpdatedCommitResult.getMallType().equals(Constants.amazon)){
		return (AbstractShopDataConsumer<I,R>) new AmazonShopDataConsumer(priceUpdatedCommitResult);
	}
	if(priceUpdatedCommitResult.getMallType().equals(Constants.yihaodian)||priceUpdatedCommitResult.getMallType().equals(Constants.yihaoshangcheng)){
		return (AbstractShopDataConsumer<I,R>) new YHDShopDataConsumer(priceUpdatedCommitResult);
	}
	
	return null;
}

}
